package com.example.publisher.config;

import org.springframework.amqp.core.DirectExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @project: kaoshi
 * @description:
 * @author: cjq
 * @create: 2022-11-07 8:40
 **/
@Configuration
public class SendMessageConfig {
    public static final String CJQ_SEND_MESSAGE_EXCHANGE_NAME = "cjq.send.message.exchange.name";
    public static final String CJQ_SEND_MESSAGE_ROUTING_KEY_NAME = "cjq.send.message.routing.key.name";

    @Bean
    DirectExchange directExchange(){
        return new DirectExchange(CJQ_SEND_MESSAGE_EXCHANGE_NAME);
    }
}
